package com.example.rxjavacoredemo.rxjava;

public interface Emitter<T> {

    // 发出正常信号
    void onNext(T value);

    // 发出异常信号
    void onError(Throwable throwable);

    // 发出完成信号
    void onComplete();
}
